26.7 Aktualisieren der Datenbank 

26.7.1 Aktualisieren mit dem »CommandBuilder«-Objekt 

Eine DataTable können Sie mit Daten aus jeder Datenquelle füllen. Handelt es sich dabei um eine Datenbank und können die Benutzer die Daten auch ändern, müssen die Änderungen zu einem bestimmten Zeitpunkt an die Datenbank übermittelt werden. Des Öfteren habe ich bereits die Update-Methode des DataAdapters erwähnt, die eine Verbindung zu der Datenbank aufbaut, um deren Datenbestand zu aktualisieren. Vielleicht haben Sie auch schon die Update-Methode ausgetestet, nachdem Sie Zeilen Ihres DataSets geändert hatten. Sie werden dabei bestimmt einen Laufzeitfehler erhalten haben. Wenn nicht, ergänzen Sie den Code des Beispiels DataRowVersionDemo wie gezeigt:

Wo liegt aber die Ursache des nun auftretenden Laufzeitfehlers?

Denken wir einmal daran, wie die Abfolge ist, bis der DataAdapter eine Auswahlabfrage an die Datenbank schickt. Wir hatten ein Command-Objekt erzeugt und diesem das SELECT-Statement übergeben. Bei der Instanziierung gaben wir dem DataAdapter das Command-Objekt über den Konstruktoraufruf bekannt. Der DataAdapter speichert das in seiner Eigenschaft SelectCommand.

Der DataAdapter hat aber noch drei weitere Eigenschaften, die nach einem Command-Objekt verlangen:

InsertCommand

DeleteCommand

UpdateCommand

So wie über SelectCommand die vom DataAdapter abzusetzende Auswahlabfrage bekannt ist, benötigt der Adapter auch noch Command-Objekte, welche die Statements INSERT, DELETE und UPDATE beschreiben.

Selbstständig wird der DataAdapter dieses Aktualisierungsstatement nicht bereitstellen, obwohl er das durchaus könnte. Denn anhand der SELECT-Abfrage ließe sich auch nach festgeschriebenen Kriterien das Aktualisieren eigenständig in die Hand nehmen. Dann hätte wir jedoch mit einem riesengroßen Nachteil zu leben, denn uns würde eine konkrete Aktualisierungslogik vorgeschrieben, ohne uns die Freiheit zu geben, selbst Einfluss darauf ausüben zu können. Einfluss auf die Aktualisierung ist aber dann notwendig, wenn wir Parallelitätskonflikte erwarten können. Mit anderen Worten: Andere Benutzer haben zuvor Änderungen am gleichen Datensatz vorgenommen. Dann wollen wir aber die Gewähr haben, dass Konflikte auftreten, wenn es den Anforderungen von Anwendung und Datenbank entspricht. Den Konflikten werden wir uns zum Abschluss des Kapitels zuwenden.

Der DataAdapter erzeugt also automatisch keine Aktualisierungslogik, die Eigenschaften Insert-, Update- und DeleteCommand haben den Inhalt null. Mit dieser Erkenntnis haben wir aber schon das Tor der Aktualisierung aufgeschlossen, egal ob wir eine manuell oder automatisch generierte Aktualisierungslogik anstreben. Zuerst wollen wir die automatische besprechen.

Zur Generierung von Befehlen gibt es ein providerspezifisches Objekt. Es ist der SqlCommandBuilder. Bei der Instanziierung übergeben wir dem Konstruktor die Referenz auf unseren SqlDataAdapter.

Da der SqlCommandBuilder über das SqlDataAdapter-Objekt weiß, wie die SELECT-Auswahlabfrage aussieht, erzeugt er die Befehle INSERT, DELETE und UPDATE auf dieser Grundlage, weist sie neuen Command-Objekten zu und übergibt diese schließlich den Eigenschaften UpdateCommand, InsertCommand und DeleteCommand des SqlDataAdapters.

Damit ist der DataAdapter auf alle Eventualitäten vorbereitet. Unabhängig davon, ob im DataSet eine Zeile gelöscht, hinzugefügt oder editiert worden ist, wird die Originaldatenbank anhand der Kommandos aktualisiert.

Kommen wir zurück zu dem eingangs gezeigten Codefragment. Wenn Sie vor dem Aufruf von Update wie gezeigt ein SqlCommandBuilder-Objekt erzeugen, wird die Aktualisierung erfolgreich sein.

Die von »CommandBuilder« generierten Aktualisierungsstatements

Dass ein CommandBuilder Aktualisierungscode anhand des SELECT-Statements erzeugt, habe ich oben erwähnt. Doch wie sieht der Code exakt aus?

Wir wollen uns das nun noch kurz ansehen. Grundlage dazu bildet die Abfrage:

Sie können sich die Aktualisierungsstatements ausgeben lassen, indem Sie die Methoden GetUpdateCommand, GetInsertCommand oder GetDeleteCommand des CommandBuilders aufrufen. Alle liefern ein Objekt vom Typ SqlCommand, über dessen Eigenschaft CommandText Sie das jeweilige SQL-Statement abfragen können. Es genügt, wenn wir uns nur eines der drei ansehen.

Sie können erkennen, dass hinter der WHERE-Klausel alle Spalten der SELECT-Abfrage als Suchkriterium nach dem zu editierenden Datensatz aufgeführt sind. Die Parameter @p5 bis @p8 werden mit den Daten gefüllt, die unter DataRowVersion.Original aus dem Dataset bezogen werden, @p1 bis @p4 erhalten die Daten aus DataRowVersion.Current. In gleicher Weise werden auch die INSERT- und DELETE-Statements vom CommandBuilder generiert.

26.7.2 Manuell gesteuerte Aktualisierungen 

Das Aktualisieren einer Datenquelle mit dem CommandBuilder-Objekt ist sehr einfach. Aber diese Einfachheit hat ihren Preis, denn wir müssen uns mit den Charakteristiken des Objekts abfinden und haben keinen Einfluss darauf, wie die Daten zurückgeschrieben werden, denn der CommandBuilder generiert Abfragen, die zur Identifikation einer Datenzeile in der Tabelle einer Datenbank alle Spalten einschließt, die mit SELECT abgefragt worden sind.

Was passiert nun, wenn der SqlDataAdapter eine Datenzeile aktualisieren möchte, die ein anderer Benutzer zwischenzeitlich geändert hat? Nehmen wir an, Anwender A hätte die Tabelle authors in ein DataSet geladen und den Datensatz des Autors White editiert. Anwender B hat, nachdem Anwender A die angeforderten Daten erhalten hat, die gleichen Daten abgefragt. Anwender B aktualisiert ebenfalls Daten des Autors White und speichert die Änderungen in der Originaldatenquelle. Versucht anschließend Anwender A, seine Daten in der Datenbank zu speichern, kann der DataAdapter den Datensatz nicht mehr finden, denn einer der Spalteneinträge hat sich bekanntlich durch Anwender B geändert. Die Folge ist, dass die Änderungen durch Anwender A nicht von der Datenbank übernommen werden. Es kommt zu einem Parallelitätskonflikt.

Möglicherweise entspricht das den Anforderungen an die Datenbankanwendung. Wie müssen Entwickler aber vorgehen, wenn ein »Last in wins«-Aktualisierungsszenario gefordert ist, in dem grundsätzlich immer derjenige, der als Letzter eine Datenzeile zurückschreibt, die ihm unbekannten Änderungen durch einen anderen Anwender überschreiben soll?

Es gibt auch noch andere denkbare Ansätze, wann ein Konflikt auftreten soll bzw. wann Änderungen an dem gleichen Datensatz durch zwei oder mehr Benutzer gleichermaßen akzeptiert werden können. Stellen wir uns dazu nur vor, Anwender A hätte das Feld au_fname des Autors White geändert, weil ihm aufgefallen ist, dass der Vorname in der Tabelle falsch eingetragen ist. Anwender B wiederum könnte die Mitteilung erhalten haben, dass sich die Telefonnummer desselben Autors geändert hat. Sie werden mir zustimmen, dass im Grunde genommen beide mit ihren Änderungen zu ihrem Recht kommen müssten, weil beide begründet sind.

Mit den beiden letztgenannten Szenarien wird der CommandBuilder nicht umgehen können. Er scheidet deshalb aus. Wir müssen selbst die gewünschte Aktualisierung formulieren. Vom Ansatz her ist das sehr einfach. Erinnern wir uns nur, welche Aufgabe der CommandBuilder hat: Er erzeugt auf Basis der SELECT-Abfrage SQL-Statements für das Editieren (UPDATE), Einfügen (INSERT INTO) und Löschen (DELETE) einer Datenzeile Command-Objekte, die er an den DataAdapter weitergibt.

Wollen Sie ein eigenes Aktualisierungsszenario beschreiben, lassen Sie den CommandBuilder aus dem Spiel und stellen eigene Command-Objekte bereit, deren SQL-Abfragestatements sich an den aktuellen Forderungen orientieren. Hier können Sie zwei Ansätze verfolgen:

Sie rufen für jede geänderte Datenzeile die ExecuteNonQuery-Methode des Command-Objekts auf. Dazu müssen Sie Code bereitstellen, der alle geänderten Datenzeilen einer DataTable erfasst.

Sie überlassen weiterhin dem DataAdapter die Aufgabe, in der DataTable nach geänderten Datenzeilen zu suchen und diese der Reihe nach an die Datenbank zu übermitteln.

Im Folgenden werde ich Ihnen beide Alternativlösungen zum CommandBuilder vorstellen.

26.7.3 Aktualisieren mit »ExecuteNonQuery« 

Bereitstellung der Command-Objekte

Ehe wir uns ansehen, wie mit ExecuteNonQuery des Command-Objekts eine anwendungsspezifische Aktualisierung implementiert werden kann, wollen wir die Forderung spezifizieren. Dabei soll hier exemplarisch die schon bekannte Tabelle authors die Daten bereitstellen, die wir ändern wollen.

Gehen wir also davon aus, dass immer die letzte Änderung Vorrang vor allen anderen haben soll. Es ist die Formulierung des »Last in wins«-Szenarios. Eine in einer DataTable geänderte Datenzeile muss, wenn sie an die Originaldatenbank übermittelt werden soll, dort auch identifiziert werden können. Dazu dienen die Primärschlüsselspalten. Das UPDATE-Statement könnte dann beispielsweise wie folgt aussehen:

Findet der Aktualisierungsprozess in der Originaltabelle authors den Datensatz mit dem Primärschlüssel abcd, trägt er alle hinter SET aufgeführten Spalteninhalte ein. Dabei interessiert nicht im Geringsten, ob sich die Inhalte seit dem Generieren des DataSets auf Benutzerseite geändert haben oder nicht. Beachten Sie, dass sich dieses UPDATE-Statement deutlich von dem, was ein CommandBuilder erzeugen würde, unterscheidet.

Das Vorhaben war, jede geänderte Datenzeile mit ExecuteNonQuery zu übermitteln. Also benötigen wir zuerst ein Command-Objekt, das die parametrisierte Abfrage beschreibt. Dafür schreiben wir eine Methode.

Um den Code übersichtlich zu halten, enthält UPDATE nur die Angabe der drei Spalten au_id, au_lname und au_fname. Diese werden, wie auch die Angabe des Suchkriteriums, als Parameter des Command-Objekts definiert. Die Methode GetUpdateCommand liefert dem aufrufenden Code ein SqlCommand als Rückgabewert, das vollständig ausgebildet ist.

Ehe mit einer Anweisung wie

aktualisiert werden kann, müssen die Parameter gefüllt werden. Dazu dient eine eigene Methode. Weil nach dem Füllen der Parameter das Command-Objekt ausführungsfertig ist, kann sogar schon innerhalb der Methode ExecuteNonQuery aufgerufen werden. Dazu muss der Methode neben dem von GetUpdateCommand generierten Command-Objekt nur die zu aktualisierende Datenzeile bekannt sein. Beide übergeben wir der Parameterliste der Methode, die wir SubmitUpdateRow nennen.

Der Aufruf von ExecuteNonQuery liefert eine Zahl zurück, die Auskunft darüber gibt, wie viele Datenzeilen aktualisiert werden konnten. Darauf wollen wir nicht verzichten, denn Sie kann uns dabei behilflich sein, etwaige Konflikte, die beim Aktualisieren auftreten, zu behandeln. Stellen Sie sich dazu nur vor, ein anderer Anwender hätte zwischenzeitlich den betreffenden Datensatz gelöscht. Der Rückgabewert von ExecuteNonQuery und damit auch unserer benutzerdefinierten Methode wäre 0.

Beim Füllen der Parameter müssen Sie bedenken, welche Datenversion Sie in den jeweiligen Parameter eintragen müssen. Die hinter SET aufgeführten Spalten beschreiben die zu ändernden Werte. Es sind also die, die unter DataRowVersion.Current der entsprechenden Datenzeile für die Spalte zu finden sind. Übergeben Sie der Eigenschaft Value des Parameters beispielsweise mit

einen Wert, wird diese Version automatisch genommen. Um den Code besser lesbar zu machen, habe ich aber ausdrücklich DataRowVersion mit angegeben.

Etwas anders ist der Sachverhalt, wenn es darum geht, das Suchkriterium für die Aktualisierung festzulegen. Bedenken Sie, dass die Primärschlüsselspalte der Tabelle authors grundsätzlich editierbar ist und nicht ausgeschlossen werden könnte, dass der Anwender auch hier eine Änderung vorgenommen hat. Die entsprechende Datenzeile kann aber nur dann gefunden werden, wenn der Originalwert übermittelt wird. Deshalb ist es unerlässlich, dass die hinter WHERE angegebenen Spalten immer DataRowVersion.Original-Werte enthalten.

In ähnlicher Weise können Sie auch Command-Objekte bereitstellen, die gelöschte und hinzugefügte Datenzeilen beschreiben.

Alle Änderungen an die Datenquelle übermitteln

Nun müssen wir uns überlegen, wie wir diese drei Methodenpaare benutzen können. Setzen wir voraus, dass wir eine zur Aktualisierung anstehende Datenzeile über row referenzieren, könnte der Aufruf wie folgt lauten:

Damit ist der Grundstock gelegt. Aber wie kommen wir an die Referenz einer geänderten DataRow?

Liegt ein DataSet vor, das viele Datenzeilen enthält, von denen wir nicht wissen, ob eine einzelne Datenzeile geändert, hinzugefügt oder gelöscht worden ist, gilt es, einen Weg zu finden, um die Datensätze daraufhin zu untersuchen. Hier bietet sich eine Überladung der Methode Select der DataTable an.

Der erste Parameter beschreibt eine Zeichenfolge zum Filtern der Datenzeilen, der zweite eine Zeichenfolge für die Sortierrichtung. Der dritte Parameter vom Typ DataRowViewState ist der, der uns die Lösung bietet. DataRowViewState ist eine Enumeration, deren Member bitweise kombiniert werden können.

Wir können der Select-Methode der DataTable angeben, nach welchen Datenzeilenversionen wir suchen wollen. Handelt es sich um gelöschte, hinzugefügte und editierte, fassen wir das Suchkriterium in einer Variablen zusammen:

Select liefert ein Array von den Datenzeilen, die sich in irgendeiner Weise vom Original in der Datenbank unterscheiden. Das Array durchlaufen wir elementweise und prüfen dabei jeweils die Eigenschaft RowState der aktuellen DataRow. Je nachdem, ob es sich um eine gelöschte, editierte oder hinzugefügte Zeile handelt, reagieren wir mit dem Aufruf einer unserer drei SubmitXxx-Methoden.

Das DataSet mit »AcceptChanges« aktualisieren

Der Aufruf der Methode ExecuteNonQuery liefert uns als Ergebnis des Aufrufs eine Zahl, welche die Anzahl der betroffenen Datensätze angibt. Da wir für jede einzelne Datenzeile die Methode aufrufen, wird uns die Rückgabe der Zahl 1 signalisieren, ob unser Aktualisierungsversuch von der Originaldatenquelle akzeptiert worden ist. Für uns ist dieses Ergebnis von elementarer Bedeutung, denn wir haben den Aktualisierungsprozess selbst in die Hand genommen und müssen ihn nun auch noch zu einem erfolgreichen Ende bringen.

Die Update-Methode des DataAdapters sorgt automatisch dafür, dass das DataSet nach erfolgreicher Aktualisierung auf den aktuellen Stand gebracht wird. Dazu werden die Daten, die unter DataRowVersion.Original zu finden sind, durch die Daten in DataRowVersion.Current ersetzt. Außerdem wird der RowState der betreffenden Datenzeile angepasst: Zeilen, die Added oder Modified sind, werden auf Unchanged gesetzt. Gelöschte Zeilen werden endgültig aus dem DataSet entfernt.

Ist die Aktualisierung mit ExecuteNonQuery erfolgreich verlaufen, müssen wir das unsererseits ebenfalls im DataSet mitteilen, um den letzten Originalzustand im DataSet widerzuspiegeln. Es gilt demnach, den DataRowState der betreffenden Datenzeilen auf DataRowState.Unchanged zu setzen beziehungsweise erfolgreich gelöschte Datenzeilen aus dem DataSet zu entfernen. Zudem muss bei allen geänderten Datenzeilen DataRowVersion.Current in DataRowVersion.Original übernommen werden. Diese Anpassungen müssen wir jedoch nicht für jede Datenzeile der Reihe nach manuell vornehmen, denn hier hilft uns die Methode AcceptChanges weiter, die auf das DataSet, eine DataTable oder eine DataRow aufgerufen werden kann. Die Änderungen wirken sich nur auf das Objekt aus, auf das die Methode aufgerufen wird.

Klappt die Aktualisierung nicht, wäre der Aufruf von AcceptChanges falsch. Wie in einem solchen Fall reagiert werden kann, behandeln wir später. Zumindest wollen wir aber sicherstellen, dass der Anwender eine Information über den misslungenen Aktualisierungsversuch erhält. Es bietet sich hier an, der Eigenschaft RowError der betreffenden DataRow eine Zeichenfolge zu übergeben, die auf den Fehlversuch hinweist. Gleichzeitig wird die Eigenschaft HasErrors=True gesetzt.

Das Beispielprogramm

Wir wollen uns nun ein Beispielprogramm ansehen, das unsere insgesamt sechs Methoden dazu benutzt, um Änderungen an den Datenzeilen via ExecuteNonQuery zur pubs-Datenbank zu senden. Im Code werden die Änderungen hartcodiert. Dazu wird der Datensatz, der zu dem Autor White gehört, in der Weise editiert, dass wir den Autor in Black umbenennen. Zudem wird ein neuer Datensatz hinzugefügt, der neben den Feldern au_id, au_lname und au_fname auch in der Spalte contract einen Wert einträgt, da diese keine NULL-Werte erlaubt.

Sie werden spätestens dann, wenn Sie zweimal hintereinander das Programm ausführen, einen Laufzeitfehler erhalten. Grund ist, dass zum zweiten Mal ein Datensatz mit dem gleichen Primärschlüssel hinzugefügt werden soll. Konflikte dieser Art können natürlich in der Regel nicht unbehandelt bleiben. Unser Code geht aber darauf nicht weiter ein. Weiter unten werden wir uns mit der Konfliktlösung beschäftigen.

26.7.4 Manuelles Aktualisieren mit dem DataAdapter 

Änderungen an den Datenzeilen können sowohl das Löschen als auch das Hinzufügen oder Editieren einer DataRow sein. Liegen gleichzeitig verschiedenartige Änderungen vor und sollen beispielsweise nur alle gelöschten Datenzeilen der Originaldatenbank mitgeteilt werden, bietet sich der Einsatz von ExecuteNonQuery an, wie es im Abschnitt zuvor beschrieben worden ist. Sie stellen damit sicher, dass nicht alle in diesem Fall unerwünschten Änderungen gleichzeitig mitgesendet werden. Wollen Sie das DataSet aber vollständig aktualisieren, gibt es einen eleganteren und auch einfacheren Weg. Er führt über den DataAdapter und dessen Update-Methode.

Die Update-Methode arbeitet im Grunde genommen sehr ähnlich wie der Code, den wir im letzten Abschnitt in Main geschrieben hatte. Sie sucht in einem DataSet bzw. in der DataTable nach den Datenzeilen, deren DataRowState nicht Unchanged ist. Trifft die Methode auf eine in welcher Weise auch immer geänderte Datenzeile, greift sie auf ein entsprechendes Command-Objekt zurück, weist die entsprechenden Parameter zu und setzt die Änderung ab.

Der entscheidende Punkt ist, dass der DataAdapter sich nicht dafür interessiert, wie das Command-Objekt gestaltet ist und aus welcher Quelle es stammt. Wichtig ist ihm nur, dass ein gültiges Command-Objekt vorliegt.

Damit haben wir auch schon den ersten Ansatz gefunden. Wir stellen eigene Command-Objekte zur Verfügung, nennen sie updateCommand, deleteCommand und insertCommand und weisen sie den entsprechenden Eigenschaften des DataAdapters zu:

Alle drei Eigenschaften sind vom Typ SqlCommand. Ein Command-Objekt kennt durch seine Eigenschaft CommandText das SQL-Kommando, das gegen die Datenbank abgesetzt werden soll. Damit sind alle Forderungen, welche die Methode Update des DataAdapters stellt, erfüllt.

Die Implementierung der Methoden

Sehen wir uns nun die Methode an, die für das Erzeugen des Kommandos zum Absetzen einer Datenzeilenänderung verantwortlich ist. Auch bei dieser Methode sei angenommen, dass zwischenzeitliche Änderungen durch andere Benutzer bei der Aktualisierung überschrieben werden. Für das Suchkriterium für den Aktualisierungsprozess genügt deshalb auch in diesem Beispiel die Angabe des Primärschlüssels.

Wird der DataAdapter zur Aktualisierung eingesetzt, muss jedem Parameter mitgeteilt werden, aus welcher Spalte der zu editierenden DataRow der Wert für den betreffenden Parameter abgerufen werden soll, beispielsweise:

Hier teilen wir dem Parameter mit, dass er den Wert aus der Spalte au_fname beziehen soll. Standardmäßig wird der Wert aus DataRowVersion.Current bezogen. Vergessen Sie die Angabe des vierten Parameters, kann der DataAdapter die Datenzeile nicht an die Datenbank übermitteln. Haben Sie eine explizite Referenz auf den Parameter, können Sie die Spalte auch der Eigenschaft SourceColumn bekannt geben.

Die Parameter der Suchkriterien benötigen den Originalwert, um die betreffende Datenzeile in der Tabelle der Datenbank aufzuspüren. Damit der DataAdapter die erforderlichen Werte aus DataRowVersion.Original einträgt, teilen Sie das dem Parameter in seiner Eigenschaft SourceVersion mit, z.  B.:

param.SourceVersion = DataRowVersion.Original

Das auf diese Weise in der Methode erzeugte Command-Objekt wird an den Aufrufer zurückgeliefert. Wie Sie weiter oben schon gesehen haben, weisen wir dessen Referenz der Eigenschaft UpdateCommand des DataAdapters zu, der automatisch die Parameter füllt, wenn er auf eine geänderte Datenzeile trifft.

In ähnlicher Weise codieren wir auch die Methoden zum Löschen und Hinzufügen von Datenzeilen.

Das Beispielprogramm

Planen Sie die manuelle Aktualisierung unter Zuhilfenahme des DataAdapters, unterscheidet sich der Programmcode kaum von dem, den Sie auch unter Benutzung des CommandBuilders schreiben würden. Anstatt den CommandBuilder zu erzeugen, weisen Sie nur den Eigenschaften InsertCommand, DeleteCommand und UpdateCommand des DataAdapters die richtigen Command-Objekte zu und rufen anschließend Update auf. Das ist bereits alles.

Das folgende Beispielprogramm zeigt Ihnen die Vorgehensweise. Wie schon im Beispiel zuvor wird ein Datensatz hinzugefügt und der Autor White umbenannt. Sie sollten, bevor Sie das Beispielprogramm ausprobieren, etwaige Änderungen, die aus dem letzten Beispiel stammen, in der Originaldatenbank zurücksetzen. Löschen Sie also den Datensatz mit der ID 111 – 11 – 1111, und lassen Sie den Autor White auch wirklich so heißen. Er könnte noch Black sein.

26.7.5 Den zu aktualisierenden Datensatz in der Datenbank suchen 

Problembeschreibung

Ein DataSet enthält einen Teilausschnitt einer Datenbank. Sie können sich die Daten anzeigen lassen, Sie können sie aber auch ändern, neue Datensätze hinzufügen oder Datensätze löschen. Sie wissen inzwischen auch, dass Sie eine Aktualisierung auf einfache Weise mit einem CommandBuilder in die Wege leiten können. Das ist ausgesprochen simpel zu programmieren und funktioniert tadellos. Ich habe Ihnen zudem gezeigt, wie Sie ohne den CommandBuilder eine eigene Aktualisierungslogik bereitstellen können. Der Code ist vielleicht spannend, aber andererseits könnten Sie auch zu der Erkenntnis kommen, dass die investierte Zeit nicht besonders effektiv genutzt worden ist.

Dem ist bei weitem nicht so. Wahrscheinlich werden Sie sogar sehr häufig eine eigene Aktualisierungslogik generieren müssen. Ich möchte Ihnen das am Beispiel des CommandBuilders beweisen. Gehen wir davon aus, dass einer Abfrage das folgende SELECT-Statement zugrunde liegt:

Auf dieser Grundlage wird der CommandBuilder ein UpdateCommand erzeugen, das wie folgt aussieht:

In der WHERE-Klausel der UPDATE-Anweisung sind alle Spalten enthalten, die in SELECT angegeben worden sind. Die Parameter @p4 bis @p6 werden bei der Aktualisierung mit den Werten aus DataRowVersion.Original gefüttert.

Nehmen wir nun an, der Benutzer der Datenbankanwendung hätte einen Datensatz mit den folgenden Feldinhalten bezogen:

Ändert der Anwender den Zunamen in »Meier«, wird der CommandBuilder folgendes UPDATE-Statement erzeugen:

Auf der Datenbank wird nun ein Datensatz in der Autorentabelle gesucht, der genau den Kriterien entspricht, welche die WHERE-Klausel beschreibt. Wird der Datensatz gefunden, werden in den in SET aufgeführten Spalten die entsprechenden Werte eingetragen. Die Aktualisierung war erfolgreich.

Zu glauben, dass das immer so sein wird, ist utopisch, wenn mehrere Anwender ihre Änderungen an die Datenbank übermitteln können. Nehmen wir an, Anwender A ändert wie gezeigt in seinem DataSet den Datensatz, während Anwender B ebenfalls eine Änderung am gleichen Datensatz vornimmt, jedoch nicht in der Spalte au_lname, sondern in der Spalte au_fname. Aktualisiert Anwender B zuerst, werden seine editierten Daten problemlos in die Datenbank geschrieben. Versucht anschließend Anwender A, seine Änderungen zu übermitteln, schlägt der Versuch fehl, weil der Datensatz, der überschrieben werden soll, nicht mehr gefunden wird.

Merken Sie, worauf meine Ausführungen hinauslaufen? Sie müssen schon im Vorfeld der Entwicklung klären, wie Sie unter Berücksichtigung mehrerer Benutzer die Datenbank aktualisieren wollen. Je nach Ausgangssituation und den angegebenen Suchkriterien werden die Daten entweder erfolgreich in die Datenbank geschrieben, oder die Aktualisierung verursacht einen Konflikt.

Grundsätzlich können wir hinsichtlich der Kriterien zur Identifizierung eines zur Aktualisierung anstehenden Datensatzes zwischen drei Fällen unterscheiden:

Die WHERE-Klausel enthält alle Spalten der SELECT-Abfrage.

Die WHERE-Klausel enthält die Primärschlüsselspalte.

Die WHERE-Klausel enthält nur die Angabe der geänderten Spalten und der Primärschlüsselspalte.

Wir sollten uns nun mit den Konsequenzen dieser drei Varianten vertraut machen, denn die Entscheidung hat auch Einfluss darauf, wie wir mit den eventuell auftretenden Konflikten umgehen und sie lösen.

Die WHERE-Klausel enthält alle Spalten

Standardmäßig nimmt der CommandBuilder alle Spalten in der WHERE-Klausel auf, die mit SELECT abgefragt worden sind. Die Folge ist, dass der Code keine Änderungen in einer DataRow überschreiben kann, die zwischenzeitlich von anderen Anwendern vorgenommen worden sind.

Dazu ein Beispiel. Angenommen, Anwender A und Anwender B rufen die gleiche Datenzeile in der Autorentabelle ab. Ändert Anwender A die Spalte au_lname, werden alle Spalten der Abfrage in die WHERE-Klausel aufgenommen. Das UPDATE-Statement könnte dann beispielsweise wie folgt aussehen:

In der Zwischenzeit könnte auch Anwender B die Datenzeile mit dem Autor geändert haben, jedoch nicht wie Anwender A die Spalte au_lname, sondern die Spalte city.

Hat Anwender A seine Änderungen zuerst übermittelt, scheitert der Aktualisierungsversuch von Anwender B, weil keine Zeile in der Tabelle den Kriterien der WHERE-Klausel entspricht.

Bei diesem Szenario »gewinnt« immer der Anwender, der als erster seine Änderungen an die Datenbank übermittelt. Der Anwender, der seine Änderungen später zur Datenbank schickt, hat das Nachsehen. Sein Aktualisierungsversuch misslingt.

Die WHERE-Klausel enthält die Primärschlüsselspalte

Aktualisierungsszenarien, die anders ablaufen sollen als das zuvor beschriebene, erfordern das Bereitstellen benutzerdefinierter Command-Objekte. Ein denkbarer Ansatz wäre der, dass jede Aktualisierung grundsätzlich immer in den entsprechenden Datensatz der Datenbank geschrieben wird. Zwischenzeitliche Änderungen durch andere Anwender werden ohne Kenntnis darüber, was ein zweiter Anwender geändert hat, überschrieben. Deshalb wird diese Art der Aktualisierung auch als »Last in wins« bezeichnet.

Bei dieser Form der Aktualisierung muss nur der betroffene Datensatz eindeutig identifiziert werden. Deshalb wird hinter der WHERE-Klausel auch nur der Primärschlüssel der Datenzeile angegeben.

Halten wir uns nun die Situation vor Augen. Wieder helfen uns die beiden fiktiven Anwender A und B dabei, den Sachverhalt zu verstehen. Beide Anwender rufen parallel die gleiche Datenzeile ab und nehmen Änderungen an einer der Spalten vor. Anwender A aktualisiert die Originaldatenbank zuerst. Wie das UPDATE-Statement aussieht, spielt dabei noch nicht einmal eine Rolle. Anwender B übermittelt seine Änderung erst später. Nehmen wir an, Anwender B hätte den Inhalt in der Spalte city verändert, könnte sein vollständiges Aktualisierungsstatement wie folgt lauten:

Die Aktualisierung wird erfolgreich sein, wenn der Datensatz mit der angegebenen au_id in der Tabelle gefunden wird. Die Änderungen von Anwender A sieht Anwender B nicht und wird vielleicht auch niemals erfahren, welche Daten Anwender A überschrieben hat. Die Identifizierung der zu ändernden Datenzeile nur anhand der Primärschlüsselspalte ist folglich auch denkbar ungeeignet, wenn Sie vermeiden müssen, dass Anwender B unwissentlich geänderte Daten überschreibt. Können Sie davon ausgehen, dass die letzte Aktualisierung zweifelsfrei diejenige mit den »besten« Daten ist, sollten Sie sich für diese Alternative entscheiden.

Angabe der geänderten Spalten

Die beiden vorhergehend beschriebenen Szenarien sind ausgesprochen gegensätzlich: Entweder wird eine vorhergehende Aktualisierung kompromisslos überschrieben, oder der Anwender, der als zweiter versucht, seine Änderungen zu übermitteln, hat sich mit einem Konflikt auseinander zu setzen.

Dadurch, dass Sie mit ADO.NET selbst die Aktualisierungslogik bereitstellen können, können Sie auch einen Kompromiss schließen und in der WHERE-Klausel neben der Primärschlüsselspalte auch die Spalten angeben, die der Anwender selbst verändert hat.

Eine kurze Beschreibung der Situation. Anwender A und Anwender B rufen gleichzeitig die gleiche Zeile mit Autorendaten ab. Anwender A ändert die Spalte au_lname, Anwender B die Spalte city. Anwender A übermittelt als erster seine Änderungen. Das UPDATE-Statement wie folgt aus:

Bei den Spalteninhalten, die hinter WHERE aufgeführt sind, handelt es sich um die Originaldaten, die der Anwender beim Füllen des DataSets erhalten hat.

Die UPDATE-Abfrage, die Anwender B nach Anwender A an die Datenbank sendet, sucht aber nach anderen Gesichtspunkten den zu aktualisierenden Datensatz:

Der Datensatz kann auch bei der später erfolgenden Aktualisierung immer noch eindeutig in der Tabelle der Autoren identifiziert werden. Damit werden auch die Änderungen, die Anwender B vorgenommen hat, in die Tabelle geschrieben, ohne dass die Änderungen von Anwender A überschrieben werden. Beide kommen zu ihrem Recht, solange sie unterschiedliche Spalten editiert haben.

Es sollte an dieser Stelle erwähnt werden, dass die Aktualisierungslogik des Command-Objekts dynamisch zur Laufzeit erzeugt werden muss, da Sie nicht wissen, welche Spalten von den Änderungen des jeweiligen Benutzers betroffen sind. Hierzu vergleichen Sie DataRowVersion.Current und DataRowVersion.Original jeder Spalte einer Datenzeile und »schrauben« sich auf diese Weise die Zeichenfolge des UDATE-Befehls zusammen, bevor Sie das Command–Objekt damit füttern. Die Codierung dazu kann, je nachdem, wie viele Spalte die Datenzeile hat, relativ aufwändig werden. Das ist der große Nachteil dieser Aktualisierung.

Fazit

Einen Tipp zu geben, welche Suchkriterien zu bevorzugen sind, ist nicht möglich. Sie müssen genau analysieren, welche Vorstellungen Sie oder Ihr Kunde haben. Wahrscheinlich werden Sie damit sogar heftige Diskussionen auslösen, bevor die endgültige Entscheidung fällt. Aber das liegt in der Natur der Sache, denn jede Datenbank ist spezifisch, und jede Datenbankanwendung muss anderen Kriterien genügen.

Wichtig ist es zu wissen, dass Sie mit ADO.NET ein Werkzeug in den Händen halten, das alle Möglichkeiten offen lässt. Wenn Sie Glück haben, genügt die Aktualisierungslogik des CommandBuilders den Ansprüchen. Dann wird die Aktualisierung zu einem Kinderspiel. Wenn nicht, erzeugen Sie ein UPDATE-Statement nach den Vorgaben, die an die Anwendung gestellt werden.

26.7.6 Den Benutzer über die fehlgeschlagenen Aktualisierungen informieren 

Stehen mehrere Datenzeilen zur Aktualisierung an, wird der DataAdapter versuchen, eine nach der anderen an die Datenbank zu senden. Wie aber wird sich der DataAdapter verhalten, wenn eine der Datenzeilen einen Konflikt verursacht? Der DataAdapter wird eine DBConcurrencyException auslösen und die verbleibenden Änderungen nicht mehr an die Datenbank schicken. So ist das Standardverhalten.

Sie können den DataAdapter auch anweisen, nach einem etwaigen Konflikt seine Aufgabe fortzusetzen und auch die verbleibenden Änderungen zu übermitteln. Dazu setzen Sie die Eigenschaft ContinueUpdateOnError=True. Das hat weit reichende Konsequenzen, denn nun verursacht ein fehlgeschlagener Aktualisierungsversuch keine Ausnahme mehr. Stattdessen wird die Eigenschaft HasErrors des entsprechenden DataRow-Objekts auf True gesetzt, ebenso die gleichnamige Eigenschaft des DataSets und der DataTable. Eine DataRow hat auch eine Eigenschaft RowError. Diese enthält nach dem misslungenen Versuch eine Fehlermeldung.

Im folgenden Beispielcode wird der Einsatz der Eigenschaften ContinueUpdateOnError, HasErrors und RowError gezeigt. Die Command-Objekte werden von den schon bekannten Methoden CreateUpdateCommand, CreateDeleteCommand und CreateInsertCommand generiert. Um eine etwas größere »Spielwiese« zu haben, ist das Suchkriterium von CreateUpdateCommand um eine Spalte (au_lname) ergänzt worden.

Geändert wird erneut der Datensatz des Autors White in der Tabelle authors. Sorgen Sie deshalb vor dem ersten Ausführen dafür, den Ursprungszustand der Tabelle wieder herzustellen. Außerdem wird erneut ein Datensatz zur Tabelle hinzugefügt. In Main wird die laufende Anwendung nach dem Füllen des DataSets unterbrochen. Das ist der Moment, um beispielsweise mit dem Enterprise Manager des SQL Servers den Datensatz des Autors White zu editieren. Damit simulieren Sie einen zweiten Anwender. Ändern Sie dabei die Spalte au_lname oder au_id, provozieren Sie den Parallelitätskonflikt. Es erscheint an der Konsole eine Fehlermeldung. Editieren Sie jedoch eine andere Spalte, werden beide Aktualisierungen von der Datenbank akzeptiert.

Nach dem Aufruf von Update auf den DataAdapter wird zuerst mit

das DataSet dahingehend untersucht, ob überhaupt ein Konflikt vorliegt. HasErrors ist False, wenn die Datenbank die Änderungen angenommen hat. True signalisiert hingegen, dass wir alle Datenzeilen in der Tabelle des DataSets durchlaufen müssen, um die konfliktverursachenden Zeilen zu finden. Fündig wird der Code, wenn er auf eine Datenzeile mit HasErrors=True trifft.

Jetzt können wir reagieren. Im einfachsten Fall lassen wir uns zumindest die ID des betreffenden Übeltäters ausgeben – so wie in diesem Beispiel. Sie können die Information natürlich auch dazu benutzen, dem Benutzer die Chance zu geben, die Konfliktursache zu beseitigen, denn der Verursacher ist ermittelt.

26.7.7 Die konfliktverursachenden Datenzeilen bei der Datenbank abfragen 

Meist genügt es nicht nur zu wissen, wer Konfliktverursacher ist. Es wird darüber hinaus auch eine Lösung angestrebt. Das bedarf aber einer genaueren Analyse der Umstände. Ich möchte Ihnen das kurz erläutern.

Wird versucht, einen bereits vorhandenen Primärschlüssel für einen neuen Datensatz ein zweites Mal zu vergeben, scheint die Lösung des Problems noch recht einfach zu sein: Es muss dann nur ein anderer Primärschlüssel vergeben werden. Aber das könnte eine falsche Entscheidung sein. Können Sie denn sicherstellen, dass nicht zwei Anwender versuchen, den gleichen Datensatz zur Tabelle hinzuzufügen? Wenn Sie diese Situation nicht berücksichtigen, liegen im schlimmsten Fall zwei identische Datensätze vor.

Weiterhin stellt sich auch die Frage, warum eine geänderte Datenzeile nicht erfolgreich aktualisiert werden konnte. Die Ursache könnte sein, dass ein anderer Anwender seinerseits den Datensatz geändert hat, es könnte aber auch sein, dass der Datensatz gar nicht mehr existiert, weil er in der Originaltabelle gelöscht worden ist.

Vielleicht merken Sie, es fehlt uns bisher an Informationen, um präzise Lösungen erarbeiten und codieren zu können. Der Ansatz zur Lösungsfindung ist aber nicht im aktuellen DataSet zu finden, sondern in der Datenbank selbst. Was wir brauchen, ist eine neue Originalversion der konfliktverursachenden Datenzeile.

Der DataAdapter hilft uns weiter. Er löst nämlich für jede zu aktualisierende Datenzeile zwei Ereignisse aus, wenn anstehende Änderungen über die Methode Update an die Datenbank übermittelt werden:

RowUpdating

RowUpdated

RowUpdating wird ausgelöst, bevor eine Zeile übermittelt wird, RowUpdated tritt unmittelbar nach der Übermittlung auf. Für unsere Lösung untersuchen wir im Ereignishandler nach der Übermittlung den zweiten Parameter vom Typ SqlRowUpdatedEventArgs. Mehrere Eigenschaften dieses Typs unterstützen uns bei unserem weiteren Vorgehen.

Der Vollständigkeit halber folgt jetzt auch noch die Tabelle mit den Membern der Enumeration UpdateStatus, die von der Eigenschaft Status des SqlRowUpdatedEventArgs-Objekts offengelegt wird.

Wie können wir nun das Ereignis zu unserem Nutzen einsetzen?

Es gilt zunächst einmal festzustellen, ob das Updaten einer Datenzeile zu einem Konflikt geführt hat. Hierzu prüfen wir, ob die Eigenschaft Status des SqlRowUpdatedEventArgs-Objekts den Enumerationswert UpdateStatus.ErrorsOccured aufweist.

Alle konfliktverursachenden Datenzeilen können in einem DataSet zusammengefasst werden, das sich nach kompletter Aktualisierung auswerten lässt. Dazu muss der aktuelle Stand der konfliktverursachenden Datenzeilen aus der Originaldatenbank bezogen werden, damit Benutzer oder Programmcode die Basis zu einer möglichen Entscheidung hinsichtlich einer Konfliktlösung haben. Im Ereignishandler wird deshalb eine parametrisierte Abfrage, die gegen die Datenbank abgesetzt werden soll, zusammengeschraubt (aber zunächst noch nicht ausgeführt). Sinnvollerweise wird dabei als Parameter nur der Primärschlüssel der konfliktverursachenden Datenzeile verwendet. Abgefragt werden von der Datenbank die Inhalte aller im Zusammenhang mit der Aktualisierung interessierenden Spalten.

daConflict ist hierbei die Referenz auf ein SqlDataAdapter-Objekt.

Grundsätzlich können beim Aktualisieren einer Datenzeile zwei verschiedene Exceptions auftreten:

SqlException

DBConcurrencyException

SqlException beschreibt eine Ausnahme, wenn SQL Server einen Fehler zurückgibt. Das wäre beispielsweise der Fall, wenn ein Datensatz hinzugefügt wird mit einem Primärschlüssel, der in der Tabelle bereits existiert.

DBConcurrencyException hingegen wird ausgelöst, wenn eine Parallelitätsverletzung vorliegt. Das ist der Fall, wenn die Rückgabe der Anzahl der aktualisierten Datenzeilen 0 ist.

Um festzustellen, welche Ausnahme ausgelöst worden ist, brauchen Sie nur den in der Eigenschaft Errors des SqlRowUpdatedEventArgs-Objekts enthaltenen Ausnahmetyp zu untersuchen. Ist dieser bekannt, können Sie die parametrisierte Abfrage starten. Die Anzahl der zurückgelieferten Datenzeilen, es kann sich dabei nur um eine oder keine handeln, lässt weitere Rückschlüsse auf das vorherige Scheitern der Aktualisierung zu.

Betrachten wir zuerst den Fall, dass Errors ein SqlException-Objekt enthält.

Es wird die Fill-Methode des DataAdapters aufgerufen, um das Konfliktdataset zu füllen. Die parametrisierte Abfrage enthält dabei in ihrem Parameter @ID den Primärschlüssel der Datenzeile, die den Konflikt verursacht hat. Zur Erinnerung, es handelt sich dabei um den Primärschlüssel eines Datensatzes, der neu hinzugefügt werden soll, wobei der Verdacht nahe liegt, dass der Primärschlüssel bereits in der Originaltabelle vergeben ist. Wird die parametrisierte Abfrage eine Datenzeile zurückliefern, bestätigt sich der Verdacht.

Handelt es sich in Errors um DBConcurrencyException, wurde der Versuch, die Änderung an einer Datenzeile in die Originaltabelle zu schreiben, abgelehnt. Die Parallelitätsverletzung kann zwei Ursachen haben:

Ein anderer Anwender hat den Datensatz zwischenzeitlich geändert.

Der Datensatz wurde von einem anderen Anwender gelöscht.

Festzustellen, welcher der beiden Punkte zum Konflikt geführt hat, ist sehr einfach, denn nach dem Absetzen der parametrisierten Abfrage muss nur der Rückgabewert untersucht werden. Ist das Ergebnis 0, d. h., der entsprechende Datensatz wurde anhand des Primärschlüssels nicht gefunden, existiert er nicht mehr, er wurde gelöscht.

Wie mit dem Inhalt des DataSets umgegangen wird, das den aktuellen Stand der konfliktverursachenden Zeilen enthält, richtet sich nach den individuellen Bedürfnissen des Kunden, der die Anwendung einsetzt. Die Lösung kann sehr unterschiedlich ausfallen und dabei auch noch sehr komplex sein. Wir wollen daher an dieser Stelle darauf verzichten und uns stattdessen die entscheidenden Ansätze in einem Beispielprogramm im Zusammenhang ansehen.